package com.mq.rabbitmq.topic.demo1;

import org.springframework.amqp.rabbit.annotation.EnableRabbit;
import org.springframework.amqp.rabbit.annotation.RabbitListener;

/**
 * Created by Administrator on 2017/8/14.
 */
@EnableRabbit
public class TestReceiver {
    @RabbitListener(queues= TopicConfig.ROUTINGKEY1)    //监听器监听指定的Queue
    public void processC(String str) {
        System.out.println("HelloReceive1 topic message :<<<<<<<<<<<<<<<<<<:"+str);
    }

}
